package com.tang.functions;

import com.tang.bean.WaterSensor;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * MapFunction实现类
 *
 * @author tang
 * @since 2023/6/6 23:05
 */
public class MapFunctionImpl implements MapFunction<WaterSensor, String> {
    
    @Override
    public String map(WaterSensor sensor) throws Exception {
        return sensor.getId();
    }
    
}
